package com.dgw.springbootkafka.controller;


import com.dgw.springbootkafka.sender.KafkaSender;

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class KafkaController {

    //@Autowired
    private KafkaSender kafkaSender;

    @GetMapping("testKafka")
    public void testKafka() {
        kafkaSender.send();
    }
}
